a8461c0fc40e4b0ac8a53c23e60bec1febce7dcc,ambari-server/src/main/java/org/apache/ambari/server/agent/HeartBeatHandler.java,HeartBeatHandler,handleHeartBeat,#HeartBeat#,64
Before Change
Host hostObject = clusterFsm.getHost(hostname);
try {
// TODO: handle unhealthy heartbeat as well
hostObject.handleEvent(new HostEvent(hostname,
HostEventType.HOST_HEARTBEAT_HEALTHY));
} catch (InvalidStateTransitonException ex) {
hostObject.setState(HostState.INIT);
RegistrationCommand regCmd = new RegistrationCommand();
After Change
try {
if (heartbeat.getNodeStatus().getStatus()
.equals(HostStatus.Status.HEALTHY)) {
hostObject.handleEvent(new HostHealthyHeartbeatEvent(hostname, now));
} else {
hostObject.handleEvent(new HostUnhealthyHeartbeatEvent(hostname, now, null));
}
} catch (InvalidStateTransitonException ex) {
hostObject.setState(HostState.INIT);